package com.qf.common.constant;

public interface KafkaConstant {

    /**
     * 设备向程序上报数据后，向kafka发送消息使用的主题
     */
    String DEVICE_DATA_TOPIC = "device_data_topic";

    /**
     * 消费设备上报数据消费者组
     */
    String DEVICE_DATA_GROUP = "device_data_group";

    /**
     * 程序向设备发送指令，向kafka发送消息使用的主题
     */
    String DEVICE_CMD_TOPIC = "device_cmd_topic";

    /**
     * 消费向设备发送指令数据消费者组
     */
    String DEVICE_CMD_GROUP = "device_cmd_group";
}
